package com.springboot.distributed.transaction;

import com.springboot.distributed.transaction.zookeeper.TransactionMessage;

/**
 * 事务消息处理器
 *
 * @author supu
 * @date 2019-09-11 15:41
 **/
public interface TransactionMessageHandler {
    /**
     * 初始化
     *
     * @param transactionStatusHandler
     */
    void init(TransactionStatusHandler transactionStatusHandler);

    /**
     * 发送事务消息
     *
     * @param transactionMessage
     */
    void sendTransactionMessage(TransactionMessage transactionMessage);
}
